package com.godme.kafka.consumer;


import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class OperationConsumer {


    @KafkaListener(topics = "operation")
    public void operationConsumer(ConsumerRecord<String, String> record){
        System.err.println(String.format("consumer: key=%s\tvalue=%s", record.key(), record.value()));
    }
}
